// 声明一个 Map 用于存储每个请求的标识 和 取消函数
const pending = new Map()
import router from '../router/index'
import axios from "axios";
import qs from 'qs'
import { Toast } from 'vant'

console.log(process.env.NODE_ENV)
// let envInfo = import.meta.env
axios.defaults.withCredentials = true;

if(process.env.NODE_ENV==='production'){
  axios.defaults.baseURL = 'http://119.45.49.244:7002/';   //配置接口地址
}

/**
 * 添加请求
 * @param {Object} config 
 */
const addPending = (config) => {
  const url = [
    config.method,
    config.url,
    qs.stringify(config.params),
    qs.stringify(config.data)
  ].join('&');
  // console.log(url);
  config.cancelToken = config.cancelToken || new axios.CancelToken(cancel => {
    if (!pending.has(url)) { // 如果 pending 中不存在当前请求，则添加进去
      pending.set(url, cancel)
    }
  })
}
/**
 * 移除请求
 * @param {Object} config 
 */
const removePending = (config) => {
  const url = [
    config.method,
    config.url,
    qs.stringify(config.params),
    qs.stringify(config.data)
  ].join('&')
  if (pending.has(url)) { // 如果在 pending 中存在当前请求标识，需要取消当前请求，并且移除
    const cancel = pending.get(url)
    cancel(url)
    pending.delete(url)
  }
}

// 请求
axios.interceptors.request.use(config => {
  // console.log(router)
  removePending(config) // 在请求开始前，对之前的请求做检查取消操作
  addPending(config) // 将当前请求添加到 pending 中
  // other code before request
  return config
}, error => {
  return Promise.reject(error)
})

axios.interceptors.response.use(response => {
  removePending(response) // 在请求结束后，移除本次请求
  let current = router.currentRoute;
  if(response && response.data && response.data.errCode === 4){
    Toast.fail({
      message: '未登录',
      duration: 1000
    })
    router.push({
      name: 'login',
      query: Object.assign( {'redirectUrl': current.name}, current.query)
    })
  }
  return response
}, error => {
  if (axios.isCancel(error)) {
    console.log('repeated request: ' + error.message)
  } else {
    // handle error code
  }
  return Promise.reject(error)
})


/**
 * 封装get方法
 * @param url  请求url
 * @param params  请求参数
 * @returns {Promise}
 */
export function get(url, params = {}) {
  if(process.env.NODE_ENV==='production'){
    url = url.replace('/api', '')
  }
  return new Promise((resolve, reject) => {
    axios.get(url, {
        params: params,
      }).then((response) => {
        // landing(url, params, response.data);
        resolve(response);
      })
      .catch((error) => {
        reject(error);
      });
  });
}

/**
 * 封装post请求
 * @param url
 * @param data
 * @returns {Promise}
 */

export function post(url, data) {
  // 如果是生产环境，就把/api去掉
  if(process.env.NODE_ENV==='production'){
    url = url.replace('/api', '')
  }
  return new Promise((resolve, reject) => {
    axios.post(url, data).then(
      (response) => {
        //关闭进度条
        resolve(response);
      },
      (err) => {
        reject(err);
      }
    );
  });
}


/**
 * 清空 pending 中的请求（在路由跳转时调用）
 */
export const clearPending = () => {
  for (const [url, cancel] of pending) {
    cancel(url)
  }
  pending.clear()
}

router.beforeEach((to, from, next) => {
  clearPending()
  next()
})